package com.sysd.server.handler;

import com.sysd.bean.GroupMessage;
import com.sysd.server.handler.base.AbstractMessageHandler;
import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext;
import org.springframework.stereotype.Component;

/**
 * @description: 群组消息
 * @author: bsh
 * @date: 2025/6/13 17:03
 */
@Component
@ChannelHandler.Sharable
public class GroupMessageHandler extends AbstractMessageHandler<GroupMessage> {

    /**
     * 需要子类重写的消息
     *
     * @param ctx 上下文
     * @param msg 消息
     */
    @Override
    public void channelRead1(ChannelHandlerContext ctx, GroupMessage msg) {
        //todo 这里有个难点，因为是分布式系统，所以我们需要获取到所有的用户其实有点难，还有已读回执怎么确保这条消息已经被读了
        //先找到本服务范围里面的信息，这里可以这样设计，把所有的用户存到redis的set里面，需要用的时候取用
        //消息的已读回执可以用last_ack_msg_id,这样只需要比较就知道那一些消息没有被读了
    }


}
